//
//  RxEMGroupDelegateObservable.swift
//  swiftim
//
//  Created by yangjian on 2023/8/7.
//

import Foundation



import HyphenateChat
import RxSwift



class RXEMGroupObservable: NSObject,EMGroupManagerDelegate {
//    public let rx_conversationListDidUpdate = PublishSubject<[EMConversation]>();
//    public let rx_messagesDidReceive = PublishSubject<[EMChatMessage]>();
//    public let rx_cmdMessagesDidReceive = PublishSubject<[EMChatMessage]>();
//    public let rx_messagesDidRead = PublishSubject<[EMChatMessage]>();
//    public let rx_onConversationRead = PublishSubject<(String,String)>();
//    public let rx_messageStatusDidChange = PublishSubject<(EMChatMessage,EMError?)>();

    
    
    func userDidJoin(_ aGroup: EMGroup, user aUsername: String) {
        
    }
    
//    func messageStatusDidChange(_ aMessage: EMChatMessage, error aError: EMError?) {
//        rx_messageStatusDidChange.onNext((aMessage,aError))
//    }
//    func conversationListDidUpdate(_ aConversationList: [EMConversation]) {
//        rx_conversationListDidUpdate.onNext(aConversationList);
//    }
//    func messagesDidReceive(_ aMessages: [EMChatMessage]) {
//        rx_messagesDidReceive.onNext(aMessages);
//    }
//    func cmdMessagesDidReceive(_ aCmdMessages: [EMChatMessage]) {
//        rx_cmdMessagesDidReceive.onNext(aCmdMessages);
//    }
//    func messagesDidRead(_ aMessages: [EMChatMessage]) {
//        rx_messagesDidRead.onNext(aMessages)
//    }
//    func onConversationRead(_ from: String, to: String) {
//        rx_onConversationRead.onNext((from,to))
//    }
    
    
}
